package my.yuan.ms.rediskafkams.config;

import my.yuan.ms.rediskafkams.controller.vo.MsVO;
import my.yuan.ms.rediskafkams.utils.ProtostuffUtil;
import org.apache.kafka.common.serialization.Serializer;

/**
 * @author zzMh
 * @Description TODO
 */
public class MsVoKafkaSerializer implements Serializer<MsVO> {
    @Override
    public byte[] serialize(String s, MsVO msVO) {
        return ProtostuffUtil.serializer(msVO, MsVO.class);
    }
}
